package com.ehotting.mqbd.core.service.mq;

import com.ehotting.mqbd.api.bean.MQDataAble;

import java.util.concurrent.FutureTask;

public interface MQServiceAble {

    public void request(MQDataAble data);

    public MQDataAble request(MQDataAble data, boolean sync) ;
    /**
     *
     * @param data 数据实体
     * @param timeout 超时，单位：秒
     * @return
     */
    public MQDataAble request(MQDataAble data,long timeout);




    public <T> FutureTask requestFuture(MQDataAble data, long timeout);


}
